home *** CD-ROM | disk | FTP | other *** search
/ PC World Komputer 2010 April / PCWorld0410.iso / hity wydania / Ubuntu 9.10 PL / karmelkowy-koliberek-9.10-netbook-remix-PL.iso / casper / filesystem.squashfs / usr / share / hplip / fax / pmlfax.pyc (.txt) < prev    next >
Python Compiled Bytecode  |  2009-10-28  |  25KB  |  704 lines
  1. # Source Generated with Decompyle++
  2. # File: in.pyc (Python 2.6)
  3.  
  4. import sys
  5. import os
  6. import os.path as os
  7. import struct
  8. import time
  9. import threading
  10. from base.g import *
  11. from base.codes import *
  12. from base import device, utils, pml, codes
  13. from prnt import cups
  14. from fax import *
  15. PAGE_FLAG_NONE = 0
  16. PAGE_FLAG_NEW_PAGE = 1
  17. PAGE_FLAG_END_PAGE = 2
  18. PAGE_FLAG_NEW_DOC = 4
  19. PAGE_FLAG_END_DOC = 8
  20. PAGE_FLAG_END_STREAM = 16
  21. MAJOR_VER = 2
  22. MINOR_VER = 0
  23. MFPDTF_RASTER_BITMAP = 0
  24. MFPDTF_RASTER_GRAYMAP = 1
  25. MFPDTF_RASTER_MH = 2
  26. MFPDTF_RASTER_MR = 3
  27. MFPDTF_RASTER_MMR = 4
  28. MFPDTF_RASTER_RGB = 5
  29. MFPDTF_RASTER_YCC411 = 6
  30. MFPDTF_RASTER_JPEG = 7
  31. MFPDTF_RASTER_PCL = 8
  32. MFPDTF_RASTER_NOT = 9
  33. DT_UNKNOWN = 0
  34. DT_FAX_IMAGES = 1
  35. DT_SCANNED_IMAGES = 2
  36. DT_DIAL_STRINGS = 3
  37. DT_DEMO_PAGES = 4
  38. DT_SPEED_DIALS = 5
  39. DT_FAX_LOGS = 6
  40. DT_CFG_PARMS = 7
  41. DT_LANG_STRS = 8
  42. DT_JUNK_FAX_CSIDS = 9
  43. DT_REPORT_STRS = 10
  44. DT_FONTS = 11
  45. DT_TTI_BITMAP = 12
  46. DT_COUNTERS = 13
  47. DT_DEF_PARMS = 14
  48. DT_SCAN_OPTIONS = 15
  49. DT_FW_JOB_TABLE = 17
  50. RT_START_PAGE = 0
  51. RT_RASTER = 1
  52. RT_END_PAGE = 2
  53. FIXED_HEADER_SIZE = 8
  54. IMAGE_VARIANT_HEADER_SIZE = 10
  55. DIAL_STRINGS_VARIANT_HEADER_SIZE = 6
  56. FAX_IMAGE_VARIANT_HEADER_SIZE = 74
  57. SOP_RECORD_SIZE = 36
  58. RASTER_RECORD_SIZE = 4
  59. EOP_RECORD_SIZE = 12
  60. DIAL_STRING_RECORD_SIZE = 51
  61. PAGE_FLAG_NEW_PAGE = 1
  62. PAGE_FLAG_END_PAGE = 2
  63. PAGE_FLAG_NEW_DOC = 4
  64. PAGE_FLAG_END_DOC = 8
  65. PAGE_FLAG_END_STREAM = 16
  66. SRC_UNKNOWN = 0
  67. SRC_HOST = 2
  68. SRC_SCANNER = 5
  69. SRC_HOST_THEN_SCANNER = 6
  70. SRC_SCANNER_THEN_HOST = 7
  71. TTI_NONE = 0
  72. TTI_PREPENDED_TO_IMAGE = 1
  73. TTI_OVERLAYED_ON_IMAGE = 2
  74. RASTER_DATA_SIZE = 504
  75.  
  76. class PMLFaxDevice(FaxDevice):
  77.     
  78.     def __init__(self, device_uri = None, printer_name = None, callback = None, fax_type = FAX_TYPE_NONE, disable_dbus = False):
  79.         FaxDevice.__init__(self, device_uri, printer_name, callback, fax_type, disable_dbus)
  80.         self.send_fax_thread = None
  81.         self.upload_log_thread = None
  82.  
  83.     
  84.     def setPhoneNum(self, num):
  85.         return self.setPML(pml.OID_FAX_LOCAL_PHONE_NUM, str(num))
  86.  
  87.     
  88.     def getPhoneNum(self):
  89.         return utils.printable(str(self.getPML(pml.OID_FAX_LOCAL_PHONE_NUM)[1]))
  90.  
  91.     phone_num = property(getPhoneNum, setPhoneNum, doc = 'OID_FAX_LOCAL_PHONE_NUM')
  92.     
  93.     def setStationName(self, name):
  94.         return self.setPML(pml.OID_FAX_STATION_NAME, str(name))
  95.  
  96.     
  97.     def getStationName(self):
  98.         return utils.printable(str(self.getPML(pml.OID_FAX_STATION_NAME)[1]))
  99.  
  100.     station_name = property(getStationName, setStationName, doc = 'OID_FAX_STATION_NAME')
  101.     
  102.     def setDateAndTime(self):
  103.         t = time.localtime()
  104.         p = struct.pack('BBBBBBB', t[0] - 2000, t[1], t[2], t[6] + 1, t[3], t[4], t[5])
  105.         log.debug(repr(p))
  106.         return self.setPML(pml.OID_DATE_AND_TIME, p)
  107.  
  108.     
  109.     def uploadLog(self):
  110.         if not self.isUloadLogActive():
  111.             self.upload_log_thread = UploadLogThread(self)
  112.             self.upload_log_thread.start()
  113.             return True
  114.         return False
  115.  
  116.     
  117.     def isUploadLogActive(self):
  118.         if self.upload_log_thread is not None:
  119.             return self.upload_log_thread.isAlive()
  120.         return False
  121.  
  122.     
  123.     def waitForUploadLogThread(self):
  124.         if self.upload_log_thread is not None and self.upload_log_thread.isAlive():
  125.             self.upload_log_thread.join()
  126.         
  127.  
  128.     
  129.     def sendFaxes(self, phone_num_list, fax_file_list, cover_message = '', cover_re = '', cover_func = None, preserve_formatting = False, printer_name = '', update_queue = None, event_queue = None):
  130.         if not self.isSendFaxActive():
  131.             self.send_fax_thread = PMLFaxSendThread(self, self.service, phone_num_list, fax_file_list, cover_message, cover_re, cover_func, preserve_formatting, printer_name, update_queue, event_queue)
  132.             self.send_fax_thread.start()
  133.             return True
  134.         return False
  135.  
  136.  
  137.  
  138. class PMLUploadLogThread(threading.Thread):
  139.     
  140.     def __init__(self, dev):
  141.         threading.Thread.__init__(self)
  142.         self.dev = dev
  143.  
  144.     
  145.     def run(self):
  146.         STATE_DONE = 0
  147.         STATE_ABORT = 10
  148.         STATE_SUCCESS = 20
  149.         STATE_BUSY = 25
  150.         STATE_DEVICE_OPEN = 28
  151.         STATE_CHECK_IDLE = 30
  152.         STATE_REQUEST_START = 40
  153.         STATE_WAIT_FOR_ACTIVE = 50
  154.         STATE_UPLOAD_DATA = 60
  155.         STATE_DEVICE_CLOSE = 70
  156.         state = STATE_CHECK_IDLE
  157.         while state != STATE_DONE:
  158.             if state == STATE_ABORT:
  159.                 continue
  160.             if state == STATE_SUCCESS:
  161.                 continue
  162.             None if state == STATE_BUSY else None<EXCEPTION MATCH>Error
  163.             if state == STATE_CHECK_IDLE:
  164.                 state = STATE_REQUEST_START
  165.                 ul_state = self.getCfgUploadState()
  166.                 if ul_state != pml.UPDN_STATE_IDLE:
  167.                     state = STATE_BUSY
  168.                 
  169.             ul_state != pml.UPDN_STATE_IDLE
  170.             if state == STATE_REQUEST_START:
  171.                 state = STATE_WAIT_FOR_ACTIVE
  172.                 self.dev.setPML(pml.OID_FAX_CFG_UPLOAD_DATA_TYPE, pml.FAX_CFG_UPLOAD_DATA_TYPE_FAXLOGS)
  173.                 self.dev.setPML(pml.OID_DEVICE_CFG_UPLOAD, pml.UPDN_STATE_REQSTART)
  174.                 continue
  175.             if state == STATE_WAIT_FOR_ACTIVE:
  176.                 state = STATE_UPLOAD_DATA
  177.                 tries = 0
  178.                 while True:
  179.                     tries += 1
  180.                     ul_state = self.getCfgUploadState()
  181.                     if ul_state == pml.UPDN_STATE_XFERACTIVE:
  182.                         break
  183.                     
  184.                     if ul_state in (pml.UPDN_STATE_ERRORABORT, pml.UPDN_STATE_XFERDONE):
  185.                         log.error('Cfg upload aborted!')
  186.                         state = STATE_ERROR
  187.                         break
  188.                     
  189.                     if tries > 10:
  190.                         state = STATE_ERROR
  191.                         log.error('Unable to get into active state!')
  192.                         break
  193.                     
  194.                     time.sleep(0.5)
  195.                 continue
  196.             if state == STATE_UPLOAD_DATA:
  197.                 continue
  198.             if state == STATE_DEVICE_CLOSE:
  199.                 self.dev.close()
  200.                 continue
  201.  
  202.  
  203.  
  204. class PMLFaxSendThread(FaxSendThread):
  205.     
  206.     def __init__(self, dev, service, phone_num_list, fax_file_list, cover_message = '', cover_re = '', cover_func = None, preserve_formatting = False, printer_name = '', update_queue = None, event_queue = None):
  207.         FaxSendThread.__init__(self, dev, service, phone_num_list, fax_file_list, cover_message, cover_re, cover_func, preserve_formatting, printer_name, update_queue, event_queue)
  208.  
  209.     
  210.     def run(self):
  211.         STATE_DONE = 0
  212.         STATE_ABORTED = 10
  213.         STATE_SUCCESS = 20
  214.         STATE_BUSY = 25
  215.         STATE_READ_SENDER_INFO = 30
  216.         STATE_PRERENDER = 40
  217.         STATE_COUNT_PAGES = 50
  218.         STATE_NEXT_RECIPIENT = 60
  219.         STATE_COVER_PAGE = 70
  220.         STATE_SINGLE_FILE = 80
  221.         STATE_MERGE_FILES = 90
  222.         STATE_SINGLE_FILE = 100
  223.         STATE_SEND_FAX = 110
  224.         STATE_CLEANUP = 120
  225.         STATE_ERROR = 130
  226.         next_recipient = self.next_recipient_gen()
  227.         state = STATE_READ_SENDER_INFO
  228.         self.rendered_file_list = []
  229.         while state != STATE_DONE:
  230.             if self.check_for_cancel():
  231.                 state = STATE_ABORTED
  232.             
  233.             log.debug('STATE=(%d, 0, 0)' % state)
  234.             if state == STATE_ABORTED:
  235.                 log.error('Aborted by user.')
  236.                 self.write_queue((STATUS_IDLE, 0, ''))
  237.                 state = STATE_CLEANUP
  238.                 continue
  239.             if state == STATE_SUCCESS:
  240.                 log.debug('Success.')
  241.                 self.write_queue((STATUS_COMPLETED, 0, ''))
  242.                 state = STATE_CLEANUP
  243.                 continue
  244.             if state == STATE_ERROR:
  245.                 log.error('Error, aborting.')
  246.                 self.write_queue((STATUS_ERROR, 0, ''))
  247.                 state = STATE_CLEANUP
  248.                 continue
  249.             if state == STATE_BUSY:
  250.                 log.error('Device busy, aborting.')
  251.                 self.write_queue((STATUS_BUSY, 0, ''))
  252.                 state = STATE_CLEANUP
  253.                 continue
  254.             if state == STATE_READ_SENDER_INFO:
  255.                 log.debug('%s State: Get sender info' % '********************')
  256.                 state = STATE_PRERENDER
  257.                 
  258.                 try:
  259.                     self.dev.open()
  260.                 except Error:
  261.                     e = None
  262.                     log.error('Unable to open device (%s).' % e.msg)
  263.                     state = STATE_ERROR
  264.                 else:
  265.                     
  266.                     try:
  267.                         self.sender_name = self.dev.station_name
  268.                         log.debug('Sender name=%s' % self.sender_name)
  269.                         self.sender_fax = self.dev.phone_num
  270.                         log.debug('Sender fax=%s' % self.sender_fax)
  271.                     except Error:
  272.                         log.error('PML get failed!')
  273.                         state = STATE_ERROR
  274.  
  275.                 finally:
  276.                     self.dev.close()
  277.  
  278.                 continue
  279.             if state == STATE_PRERENDER:
  280.                 log.debug('%s State: Pre-render non-G3 files' % '********************')
  281.                 state = self.pre_render(STATE_COUNT_PAGES)
  282.                 continue
  283.             if state == STATE_COUNT_PAGES:
  284.                 log.debug('%s State: Get total page count' % '********************')
  285.                 state = self.count_pages(STATE_NEXT_RECIPIENT)
  286.                 continue
  287.             if state == STATE_NEXT_RECIPIENT:
  288.                 log.debug('%s State: Next recipient' % '********************')
  289.                 state = STATE_COVER_PAGE
  290.                 
  291.                 try:
  292.                     recipient = next_recipient.next()
  293.                     log.debug('Processing for recipient %s' % recipient['name'])
  294.                     self.write_queue((STATUS_SENDING_TO_RECIPIENT, 0, recipient['name']))
  295.                 except StopIteration:
  296.                     state = STATE_SUCCESS
  297.                     log.debug('Last recipient.')
  298.                     continue
  299.  
  300.                 self.recipient_file_list = self.rendered_file_list[:]
  301.                 continue
  302.             if state == STATE_COVER_PAGE:
  303.                 log.debug('%s State: Render cover page' % '********************')
  304.                 state = self.cover_page(recipient)
  305.                 continue
  306.             if state == STATE_SINGLE_FILE:
  307.                 log.debug('%s State: Handle single file' % '********************')
  308.                 state = self.single_file(STATE_SEND_FAX)
  309.                 continue
  310.             if state == STATE_MERGE_FILES:
  311.                 log.debug('%s State: Merge multiple files' % '********************')
  312.                 state = self.merge_files(STATE_SEND_FAX)
  313.                 continue
  314.             if state == STATE_SEND_FAX:
  315.                 log.debug('%s State: Send fax' % '********************')
  316.                 state = STATE_NEXT_RECIPIENT
  317.                 FAX_SEND_STATE_DONE = 0
  318.                 FAX_SEND_STATE_ABORT = 10
  319.                 FAX_SEND_STATE_ERROR = 20
  320.                 FAX_SEND_STATE_BUSY = 25
  321.                 FAX_SEND_STATE_SUCCESS = 30
  322.                 FAX_SEND_STATE_DEVICE_OPEN = 40
  323.                 FAX_SEND_STATE_SET_TOKEN = 50
  324.                 FAX_SEND_STATE_EARLY_OPEN = 60
  325.                 FAX_SEND_STATE_SET_PARAMS = 70
  326.                 FAX_SEND_STATE_CHECK_IDLE = 80
  327.                 FAX_SEND_STATE_START_REQUEST = 90
  328.                 FAX_SEND_STATE_LATE_OPEN = 100
  329.                 FAX_SEND_STATE_SEND_DIAL_STRINGS = 110
  330.                 FAX_SEND_STATE_SEND_FAX_HEADER = 120
  331.                 FAX_SEND_STATE_SEND_PAGES = 130
  332.                 FAX_SEND_STATE_SEND_END_OF_STREAM = 140
  333.                 FAX_SEND_STATE_WAIT_FOR_COMPLETE = 150
  334.                 FAX_SEND_STATE_RESET_TOKEN = 160
  335.                 FAX_SEND_STATE_CLOSE_SESSION = 170
  336.                 monitor_state = False
  337.                 error_state = pml.DN_ERROR_NONE
  338.                 fax_send_state = FAX_SEND_STATE_DEVICE_OPEN
  339.                 while fax_send_state != FAX_SEND_STATE_DONE:
  340.                     if self.check_for_cancel():
  341.                         log.error('Fax send aborted.')
  342.                         fax_send_state = FAX_SEND_STATE_ABORT
  343.                     
  344.                     if monitor_state:
  345.                         fax_state = self.getFaxDownloadState()
  346.                         if fax_state not in (pml.UPDN_STATE_XFERACTIVE, pml.UPDN_STATE_XFERDONE):
  347.                             log.error('D/L error state=%d' % fax_state)
  348.                             fax_send_state = FAX_SEND_STATE_ERROR
  349.                             state = STATE_ERROR
  350.                         
  351.                     
  352.                     log.debug('STATE=(%d, %d, 0)' % (STATE_SEND_FAX, fax_send_state))
  353.                     if fax_send_state == FAX_SEND_STATE_ABORT:
  354.                         monitor_state = False
  355.                         fax_send_state = FAX_SEND_STATE_RESET_TOKEN
  356.                         state = STATE_ABORTED
  357.                         continue
  358.                     if fax_send_state == FAX_SEND_STATE_ERROR:
  359.                         log.error('Fax send error.')
  360.                         error_state = self.getFaxDownloadError()
  361.                         log.debug('Error State=%d (%s)' % (error_state, pml.DN_ERROR_STR.get(error_state, 'Unknown')))
  362.                         monitor_state = False
  363.                         fax_send_state = FAX_SEND_STATE_RESET_TOKEN
  364.                         state = STATE_ERROR
  365.                         continue
  366.                     if fax_send_state == FAX_SEND_STATE_BUSY:
  367.                         log.error('Fax device busy.')
  368.                         monitor_state = False
  369.                         fax_send_state = FAX_SEND_STATE_RESET_TOKEN
  370.                         state = STATE_BUSY
  371.                         continue
  372.                     None if fax_send_state == FAX_SEND_STATE_SUCCESS else self.dev.device_state == DEVICE_STATE_NOT_FOUND
  373.                     if fax_send_state == FAX_SEND_STATE_SET_TOKEN:
  374.                         log.debug('%s State: Acquire fax token' % '********************')
  375.                         
  376.                         try:
  377.                             (result_code, token) = self.dev.getPML(pml.OID_FAX_TOKEN)
  378.                         except Error:
  379.                             log.debug('Unable to acquire fax token (1).')
  380.                             fax_send_state = FAX_SEND_STATE_EARLY_OPEN
  381.  
  382.                     None if result_code > pml.ERROR_MAX_OK else check_token == token
  383.                     if fax_send_state == FAX_SEND_STATE_EARLY_OPEN:
  384.                         log.debug('%s State: Early open' % '********************')
  385.                         fax_send_state = FAX_SEND_STATE_CHECK_IDLE
  386.                         if self.dev.fax_type == FAX_TYPE_BLACK_SEND_EARLY_OPEN:
  387.                             log.debug('Opening fax channel.')
  388.                             
  389.                             try:
  390.                                 self.dev.openFax()
  391.                             except Error:
  392.                                 e = None
  393.                                 log.error('Unable to open channel (%s).' % e.msg)
  394.                                 fax_send_state = FAX_SEND_STATE_ERROR
  395.                             except:
  396.                                 None<EXCEPTION MATCH>Error
  397.                             
  398.  
  399.                         None<EXCEPTION MATCH>Error
  400.                         log.debug('Skipped.')
  401.                         continue
  402.                     None if fax_send_state == FAX_SEND_STATE_CHECK_IDLE else dl_state == pml.UPDN_STATE_IDLE
  403.                     if fax_send_state == FAX_SEND_STATE_SET_PARAMS:
  404.                         log.debug('%s State: Set params' % '********************')
  405.                         fax_send_state = FAX_SEND_STATE_LATE_OPEN
  406.                         
  407.                         try:
  408.                             self.dev.setPML(pml.OID_DEV_DOWNLOAD_TIMEOUT, pml.DEFAULT_DOWNLOAD_TIMEOUT)
  409.                             self.dev.setPML(pml.OID_FAXJOB_TX_TYPE, pml.FAXJOB_TX_TYPE_HOST_ONLY)
  410.                             log.debug('Setting date and time on device.')
  411.                             self.dev.setDateAndTime()
  412.                         except Error:
  413.                             e = None
  414.                             log.error('PML/SNMP error (%s)' % e.msg)
  415.                             fax_send_state = FAX_SEND_STATE_ERROR
  416.                         except:
  417.                             None<EXCEPTION MATCH>Error
  418.                         
  419.  
  420.                     None<EXCEPTION MATCH>Error
  421.                     None if fax_send_state == FAX_SEND_STATE_LATE_OPEN else None<EXCEPTION MATCH>Error
  422.                     if fax_send_state == FAX_SEND_STATE_SEND_FAX_HEADER:
  423.                         log.debug('%s State: Send fax header' % '********************')
  424.                         fax_send_state = FAX_SEND_STATE_SEND_PAGES
  425.                         
  426.                         try:
  427.                             ff = file(self.f, 'r')
  428.                         except IOError:
  429.                             log.error('Unable to read fax file.')
  430.                             fax_send_state = FAX_SEND_STATE_ERROR
  431.                             continue
  432.  
  433.                         
  434.                         try:
  435.                             header = ff.read(FILE_HEADER_SIZE)
  436.                         except IOError:
  437.                             log.error('Unable to read fax file.')
  438.                             fax_send_state = FAX_SEND_STATE_ERROR
  439.                             continue
  440.  
  441.                         (magic, version, total_pages, hort_dpi, vert_dpi, page_size, resolution, encoding, reserved1, reserved2) = self.decode_fax_header(header)
  442.                     None if magic != 'hplip_g3' else None<EXCEPTION MATCH>Error
  443.                     if fax_send_state == FAX_SEND_STATE_SEND_PAGES:
  444.                         log.debug('%s State: Send pages' % '********************')
  445.                         fax_send_state = FAX_SEND_STATE_SEND_END_OF_STREAM
  446.                         page = StringIO()
  447.                         for p in range(total_pages):
  448.                             if self.check_for_cancel():
  449.                                 fax_send_state = FAX_SEND_STATE_ABORT
  450.                             
  451.                             if fax_send_state == FAX_SEND_STATE_ABORT:
  452.                                 break
  453.                             
  454.                             
  455.                             try:
  456.                                 header = ff.read(PAGE_HEADER_SIZE)
  457.                             except IOError:
  458.                                 log.error('Unable to read fax file.')
  459.                                 fax_send_state = FAX_SEND_STATE_ERROR
  460.                                 continue
  461.  
  462.                             (page_num, ppr, rpp, bytes_to_read, thumbnail_bytes, reserved2) = self.decode_page_header(header)
  463.                             log.debug('Page=%d PPR=%d RPP=%d BPP=%d Thumb=%d' % (page_num, ppr, rpp, bytes_to_read, thumbnail_bytes))
  464.                             page.write(ff.read(bytes_to_read))
  465.                             thumbnail = ff.read(thumbnail_bytes)
  466.                             page.seek(0)
  467.                             self.create_mfpdtf_fixed_header(DT_FAX_IMAGES, page_flags = PAGE_FLAG_NEW_PAGE)
  468.                             self.create_sop_record(page_num, hort_dpi, vert_dpi, ppr, rpp, encoding)
  469.                             
  470.                             try:
  471.                                 data = page.read(RASTER_DATA_SIZE)
  472.                             except IOError:
  473.                                 log.error('Unable to read fax file.')
  474.                                 fax_send_state = FAX_SEND_STATE_ERROR
  475.                                 continue
  476.  
  477.                             if data == '':
  478.                                 log.error('No data!')
  479.                                 fax_send_state = FAX_SEND_STATE_ERROR
  480.                                 continue
  481.                             
  482.                             self.create_raster_data_record(data)
  483.                             total_read = RASTER_DATA_SIZE
  484.                             while True:
  485.                                 data = page.read(RASTER_DATA_SIZE)
  486.                                 total_read += RASTER_DATA_SIZE
  487.                                 dl_state = self.getFaxDownloadState()
  488.                                 if dl_state == pml.UPDN_STATE_ERRORABORT:
  489.                                     fax_send_state = FAX_SEND_STATE_ERROR
  490.                                     break
  491.                                 
  492.                                 if self.check_for_cancel():
  493.                                     fax_send_state = FAX_SEND_STATE_ABORT
  494.                                     break
  495.                                 
  496.                                 if data == '':
  497.                                     self.create_eop_record(rpp)
  498.                                     
  499.                                     try:
  500.                                         self.write_stream()
  501.                                     except Error:
  502.                                         log.error('Channel write error.')
  503.                                         fax_send_state = FAX_SEND_STATE_ERROR
  504.  
  505.                                     break
  506.                                 else:
  507.                                     
  508.                                     try:
  509.                                         self.write_stream()
  510.                                     except Error:
  511.                                         log.error('Channel write error.')
  512.                                         fax_send_state = FAX_SEND_STATE_ERROR
  513.                                         break
  514.  
  515.                                 status = self.getFaxJobTxStatus()
  516.                                 while status == pml.FAXJOB_TX_STATUS_DIALING:
  517.                                     self.write_queue((STATUS_DIALING, 0, recipient['fax']))
  518.                                     time.sleep(1)
  519.                                     if self.check_for_cancel():
  520.                                         fax_send_state = FAX_SEND_STATE_ABORT
  521.                                         break
  522.                                     
  523.                                     dl_state = self.getFaxDownloadState()
  524.                                     if dl_state == pml.UPDN_STATE_ERRORABORT:
  525.                                         fax_send_state = FAX_SEND_STATE_ERROR
  526.                                         break
  527.                                     
  528.                                     status = self.getFaxJobTxStatus()
  529.                                 if fax_send_state not in (FAX_SEND_STATE_ABORT, FAX_SEND_STATE_ERROR):
  530.                                     while status == pml.FAXJOB_TX_STATUS_CONNECTING:
  531.                                         self.write_queue((STATUS_CONNECTING, 0, recipient['fax']))
  532.                                         time.sleep(1)
  533.                                         if self.check_for_cancel():
  534.                                             fax_send_state = FAX_SEND_STATE_ABORT
  535.                                             break
  536.                                         
  537.                                         dl_state = self.getFaxDownloadState()
  538.                                         if dl_state == pml.UPDN_STATE_ERRORABORT:
  539.                                             fax_send_state = FAX_SEND_STATE_ERROR
  540.                                             break
  541.                                         
  542.                                         status = self.getFaxJobTxStatus()
  543.                                 
  544.                                 if status == pml.FAXJOB_TX_STATUS_TRANSMITTING:
  545.                                     self.write_queue((STATUS_SENDING, page_num, recipient['fax']))
  546.                                 
  547.                                 self.create_mfpdtf_fixed_header(DT_FAX_IMAGES, page_flags = 0)
  548.                                 self.create_raster_data_record(data)
  549.                                 if fax_send_state in (FAX_SEND_STATE_ABORT, FAX_SEND_STATE_ERROR):
  550.                                     break
  551.                                     continue
  552.                             page.truncate(0)
  553.                             page.seek(0)
  554.                         
  555.                     None if fax_send_state == FAX_SEND_STATE_SEND_END_OF_STREAM else status == pml.FAXJOB_TX_STATUS_DIALING
  556.                     if fax_send_state == FAX_SEND_STATE_RESET_TOKEN:
  557.                         log.debug('%s State: Release fax token' % '********************')
  558.                         self.write_queue((STATUS_CLEANUP, 0, ''))
  559.                         
  560.                         try:
  561.                             self.dev.setPML(pml.OID_FAX_TOKEN, '\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00')
  562.                         except Error:
  563.                             log.error('Unable to release fax token.')
  564.  
  565.                         fax_send_state = FAX_SEND_STATE_CLOSE_SESSION
  566.                         continue
  567.                     if fax_send_state == FAX_SEND_STATE_CLOSE_SESSION:
  568.                         log.debug('%s State: Close session' % '********************')
  569.                         fax_send_state = FAX_SEND_STATE_DONE
  570.                         log.debug('Closing session...')
  571.                         
  572.                         try:
  573.                             mm.close()
  574.                         except NameError:
  575.                             pass
  576.  
  577.                         
  578.                         try:
  579.                             ff.close()
  580.                         except NameError:
  581.                             pass
  582.  
  583.                         if self.dev.fax_type == FAX_TYPE_BLACK_SEND_LATE_OPEN:
  584.                             log.debug('Closing fax channel.')
  585.                             self.dev.closeFax()
  586.                         
  587.                         self.dev.setPML(pml.OID_FAX_DOWNLOAD, pml.UPDN_STATE_IDLE)
  588.                         time.sleep(1)
  589.                         if self.dev.fax_type == FAX_TYPE_BLACK_SEND_EARLY_OPEN:
  590.                             log.debug('Closing fax channel.')
  591.                             self.dev.closeFax()
  592.                         
  593.                         self.dev.close()
  594.                         continue
  595.                 continue
  596.             if state == STATE_CLEANUP:
  597.                 log.debug('%s State: Cleanup' % '********************')
  598.                 if self.remove_temp_file:
  599.                     log.debug('Removing merged file: %s' % self.f)
  600.                     
  601.                     try:
  602.                         os.remove(self.f)
  603.                         log.debug('Removed')
  604.                     except OSError:
  605.                         log.debug('Not found')
  606.                     except:
  607.                         None<EXCEPTION MATCH>OSError
  608.                     
  609.  
  610.                 None<EXCEPTION MATCH>OSError
  611.                 state = STATE_DONE
  612.                 continue
  613.  
  614.     
  615.     def getFaxDownloadState(self):
  616.         (result_code, state) = self.dev.getPML(pml.OID_FAX_DOWNLOAD)
  617.         if state:
  618.             log.debug('D/L State=%d (%s)' % (state, pml.UPDN_STATE_STR.get(state, 'Unknown')))
  619.             return state
  620.         return pml.UPDN_STATE_ERRORABORT
  621.  
  622.     
  623.     def getFaxDownloadError(self):
  624.         (result_code, state) = self.dev.getPML(pml.OID_FAX_DOWNLOAD_ERROR)
  625.         if state:
  626.             return state
  627.         return pml.DN_ERROR_UNKNOWN
  628.  
  629.     
  630.     def getFaxJobTxStatus(self):
  631.         (result_code, status) = self.dev.getPML(pml.OID_FAXJOB_TX_STATUS)
  632.         if status:
  633.             log.debug('Tx Status=%d (%s)' % (status, pml.FAXJOB_TX_STATUS_STR.get(status, 'Unknown')))
  634.             return status
  635.         return pml.FAXJOB_TX_STATUS_IDLE
  636.  
  637.     
  638.     def getFaxJobRxStatus(self):
  639.         (result_code, status) = self.dev.getPML(pml.OID_FAXJOB_RX_STATUS)
  640.         if status:
  641.             log.debug('Rx Status=%d (%s)' % (status, pml.FAXJOB_RX_STATUS_STR.get(status, 'Unknown')))
  642.             return status
  643.         return pml.FAXJOB_RX_STATUS_IDLE
  644.  
  645.     
  646.     def getCfgUploadState(self):
  647.         (result_code, state) = self.dev.getPML(pml.OID_DEVICE_CFG_UPLOAD)
  648.         if state:
  649.             log.debug('Cfg Upload State = %d (%s)' % (state, pml.UPDN_STATE_STR.get(state, 'Unknown')))
  650.             return state
  651.         return pml.UPDN_STATE_ERRORABORT
  652.  
  653.     
  654.     def create_mfpdtf_fixed_header(self, data_type, send_variant = False, page_flags = 0):
  655.         header_len = FIXED_HEADER_SIZE
  656.         if send_variant:
  657.             if data_type == DT_DIAL_STRINGS:
  658.                 header_len += DIAL_STRINGS_VARIANT_HEADER_SIZE
  659.             elif data_type == DT_FAX_IMAGES:
  660.                 header_len += FAX_IMAGE_VARIANT_HEADER_SIZE
  661.             
  662.         
  663.         self.stream.write(struct.pack('<IHBB', 0, header_len, data_type, page_flags))
  664.  
  665.     
  666.     def create_mfpdtf_dial_strings(self, number):
  667.         p = struct.pack('<BBHH51s', MAJOR_VER, MINOR_VER, 1, 51, number[:51])
  668.         log.debug(repr(p))
  669.         self.stream.write(p)
  670.  
  671.     
  672.     def adjust_fixed_header_block_size(self):
  673.         size = self.stream.tell()
  674.         self.stream.seek(0)
  675.         self.stream.write(struct.pack('<I', size))
  676.  
  677.     
  678.     def create_sop_record(self, page_num, hort_dpi, vert_dpi, ppr, rpp, encoding, bpp = 1):
  679.         self.stream.write(struct.pack('<BBHHHIHHHHHHIHHHH', RT_START_PAGE, encoding, page_num, ppr, bpp, rpp, 0, hort_dpi, 0, vert_dpi, ppr, bpp, rpp, 0, hort_dpi, 0, vert_dpi))
  680.  
  681.     
  682.     def create_eop_record(self, rpp):
  683.         self.stream.write(struct.pack('<BBBBII', RT_END_PAGE, 0, 0, 0, rpp, 0))
  684.  
  685.     
  686.     def create_raster_data_record(self, data):
  687.         if not len(data) <= RASTER_DATA_SIZE:
  688.             raise AssertionError
  689.         self.stream.write(struct.pack('<BBH', RT_RASTER, 0, len(data)))
  690.         self.stream.write(data)
  691.  
  692.     
  693.     def create_mfpdtf_fax_header(self, total_pages):
  694.         self.stream.write(struct.pack('<BBBHBI20s20s20sI', MAJOR_VER, MINOR_VER, SRC_HOST, total_pages, TTI_PREPENDED_TO_IMAGE, 0, '', '', '', 0))
  695.  
  696.     
  697.     def write_stream(self):
  698.         self.adjust_fixed_header_block_size()
  699.         self.dev.writeFax(self.stream.getvalue())
  700.         self.stream.truncate(0)
  701.         self.stream.seek(0)
  702.  
  703.  
  704.